package com.study.rabbitmq.four;

import com.rabbitmq.client.Channel;
import com.study.rabbitmq.util.RabbitUtil;
import sun.misc.MessageUtils;

import java.io.IOException;
import java.util.UUID;

/**
 * 发布确认模式
 *  使用的时候 比较哪种确认方式是最好的
 *  1、单个确认
 *  2、批量确认
 *  3、异步批量确认
 * @Author chenyeqing
 * @Date 2021/9/8 21:17
 */
public class ConfirmMessage {

    public static void main(String[] args) {
        // 1. 单个确认

        // 2. 批量确认

        // 3. 异步批量确认

    }


    /**
     * 单个确认
     */
    public static void publicMessageIndividually() throws IOException {
        Channel channel = RabbitUtil.getChannel();
        // 队列的声明
        String queueName = UUID.randomUUID().toString();

        channel.queueDeclare(queueName, false, false, false, null);

        // 开启发布确认
        channel.confirmSelect();
        // 开始时间
        long start = System.currentTimeMillis();


    }

}
